package com.zisu.rabbitconsumer.test;


import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @Desc: ""
 * @Author: caixiang
 * @DATE: 2021/6/7 9:11
 */
@Configuration
public class RabbitmqConfiguration {
//    @Bean
//    public Queue helloQueue(){
//        return new Queue("helloQueue");
//    }
//
//    @Bean
//    public DirectExchange helloExchange(){
//        return new DirectExchange("helloExchange");
//    }
//
//    @Bean
//    public void bindExchangeAndQueue(){
//        BindingBuilder.bind(helloQueue()).to(helloExchange()).with("helloRouting").addArgument("x-cancel-on-ha-failover",true);
//    }
}